package com.ds.lens.flink.monitor.monitorjob.function;

import com.ds.lens.flink.monitor.common.bo.MonitorState;
import org.apache.flink.api.java.functions.KeySelector;

public class MonitorKeyKeySelector implements KeySelector<MonitorState, Long> {
    @Override
    public Long getKey(MonitorState value) throws Exception {
        return value.getKey().getMonitorId();
    }
}
